# 创建日志Topic
kafka-topics --create --topic mall-logs \
  --partitions 3 \
  --replication-factor 1 \
  --bootstrap-server kafka:9092

# 查看Topic详情
kafka-topics --describe --topic mall-logs \
  --bootstrap-server kafka:9092

# 创建错误日志Topic
kafka-topics --create --topic mall-error-logs \
  --partitions 1 \
  --replication-factor 1 \
  --bootstrap-server kafka:9092

# 创建业务日志Topic
kafka-topics --create --topic mall-business-logs \
  --partitions 1 \
  --replication-factor 1 \
  --bootstrap-server kafka:9092

# 创建统一格式日志Topic
kafka-topics --create --topic mall-unified-logs \
  --partitions 1 \
  --replication-factor 1 \
  --bootstrap-server kafka:9092